8160bf0535049e1e44baee889d981e5c9a1ddccb,rxbinding/src/main/java/com/jakewharton/rxbinding/view/ViewDragOnSubscribe.java,ViewDragOnSubscribe,call,#Subscriber#,23

Before Change


      }
    };

    Subscription subscription = AndroidSubscriptions.unsubscribeOnMainThread(new Action0() {
      @Override public void call() {
        view.setOnDragListener(null);
      }
    });
    subscriber.add(subscription);

    view.setOnDragListener(listener);
  }

After Change


    this.handled = handled;
  }

  @Override public void call(final Subscriber<? super DragEvent> subscriber) {
    checkUiThread();

    View.OnDragListener listener = new View.OnDragListener() {
      @Override public boolean onDrag(View v, DragEvent event) {
        if (handled.call(event)) {
          if (!subscriber.isUnsubscribed()) {
            subscriber.onNext(event);
          }
          return true;
        }
        return false;
      }
    };

    subscriber.add(new MainThreadSubscription() {
      @Override protected void onUnsubscribe() {
        view.setOnDragListener(null);
      }
    });

    view.setOnDragListener(listener);
  }